package com.example.demo.server.impl;

import com.example.demo.dao.ReqMessageRepository;
import com.example.demo.pojo.Reqmessage;
import com.example.demo.server.ReqMessageServer;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

/**
 * @author 刘二朋
 * @date 2020-12-02 15:28
 */
@Service
public class ReqMessageServerImpl implements ReqMessageServer {

    @Resource
    ReqMessageRepository reqMessageRepository;


    /**
     * 添加一条好友请求消息 , 到数据库 进行保存
     *
     * @param requesta 用户1
     * @param requestb 用户2
     * @param message  请求消息内容
     * @return 返回保存的请求消息
     */
    @Override
    public Reqmessage addReqmessage(String requesta, String requestb, String message) {
//        创建一个消息对象
        Reqmessage reqmessage = new Reqmessage();
        reqmessage.setRequesta(requesta);
        reqmessage.setRequestb(requestb);
        reqmessage.setMessage(message);
        return reqMessageRepository.save(reqmessage);
    }

    /**
     * 查询关于指定用的 所有的请求消息 ,
     *
     * @param id 要进行操作的用户
     * @return 返回查询到的结果
     */
    @Override
    public List<Reqmessage> selectRequestmessage(String id) {
        return reqMessageRepository.selectReqMessageId(id);
    }

    /**
     * 删除用户的 相互的请求消息
     *
     * @param id1 用户1
     * @param id2 用户2
     * @return 返回删除的条数
     */
    @Override
    public int deleteReqMessage(String id1, String id2) {
        return reqMessageRepository.deleteRequest(id1, id2);
    }
}
